package com.iatinspur.dubbo.steam;

import org.apache.dubbo.common.stream.StreamObserver;

import java.io.Serializable;

public class MyStreamObserver implements StreamObserver<Object>, Serializable {
    @Override
    public void onNext(Object data) {
        System.err.println(data);
    }

    @Override
    public void onError(Throwable throwable) {

    }

    @Override
    public void onCompleted() {
        System.err.println("结束");
    }
}
